#ifndef __DP_PTHREAD_H__
#define __DP_PTHREAD_H__

#include <pthread.h>
#include <time.h>
#include <math.h>
#include "dp_table.h"
#include "database.h"
#include "cJSON.h"
#include "mqtt_json.h"
#include "msg_queue_peer.h"
// 上报线程
void *report_thread(void *arg);

// 元宇宙上报线程
void *aiot_report_thread(void *arg);

// 存储线程
void *storage_thread(void *arg);

// 指令处理线程
void *command_handler_thread(void *arg);

//
const char* key_to_name(int key);

#endif